package com.ynet.middleground.riskmanage.mq;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author songyf
 * @description 全球捷运客户分析数据
 * @date 2021-10-19
 */
public interface WorldexCustomerAnalyticsZt {

    String JKZTFK_TO_BLXD_KHSJFX = "jkztfk-to-blxd-khsjfx";

    String JKZTFK_TO_BLXD_QLKHMD = "jkztfk-to-blxd-qlkhmd";
    
    /**
     * 往 MQ 推送消息
     *
     * @return
     */
    @Output(WorldexCustomerAnalyticsZt.JKZTFK_TO_BLXD_KHSJFX)
    MessageChannel notice();

    /**
     * 往 MQ 推送消息
     *
     * @return
     */
    @Output(WorldexCustomerAnalyticsZt.JKZTFK_TO_BLXD_QLKHMD)
    MessageChannel noticeAll();

}
